package ru.spbu.math.seabattle.client.jms.common;

import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.Topic;

public class JmsTopicHelper extends JmsHelper {

	private Topic destination;

	@Override
	protected MessageProducer createProducer(Session session, String queueName) throws JMSException {
		destination = session.createTopic(queueName);

		return session.createProducer(destination);
	}

	@Override
	public Topic getDestination() {
		return destination;
	}

}
